var mongodb = require('./mongodb');

var Schema = mongodb.mongoose.Schema;  // 模式、策略

var MessageSchema = new Schema({
	msgId : String,
	msgType: String,
	title : String,
	target: String, // 目标设备
	isWrap: Boolean, // 完整信息不需要拉去
	receive : Boolean, // 设备保持长连接即认为接收成功
	extras:{}, // 直接推送到设备的集合
	create_date : { type: Date, default: Date.now }
});

var Message = mongodb.mongoose.model("Message", MessageSchema); // 模型

var MessageDAO = function(){};

/**
 * [save description] 插入一条记录
 * @param  {[type]}   obj      [description] obj 即json对象
 * @param  {Function} callback [description]
 * @return {[type]}            [description]
 */
MessageDAO.prototype.save = function(obj, callback) {
	var instance = new Message(obj);
	instance.save(function(err) {
		callback(err);
	});
};

module.exports = new MessageDAO();
